package com.gfscold.trans.common.utils;

import com.ververica.cdc.connectors.mysql.MySqlSource;

import java.util.Properties;

public class FlinkSourceUtils {
    // 创建MySQL Source
//    public static MySqlSource<String> createMySqlSource() {
//        Properties properties = new Properties();
//        properties.setProperty("database.hostname", "localhost");
//        properties.setProperty("database.port", "3306");
//        properties.setProperty("database.user", "root");
//        properties.setProperty("database.password", "123456");
//        properties.setProperty("database.serverTimezone", "Asia/Shanghai");
//        properties.setProperty("database.serverId", "1001-1002");
//        properties.setProperty("database.whitelist", "test");
//    }
}
